package cn.iotab.iotkit.transport.api.access.handler;

import cn.iotab.iotkit.transport.api.common.message.msg.rpc.AuthBasicRequestMsg;
import cn.iotab.iotkit.transport.api.common.message.msg.rpc.AuthResponseMsg;
import cn.iotab.iotkit.transport.api.common.message.msg.rpc.AuthX509RequestMsg;
import com.google.common.util.concurrent.ListenableFuture;

/**
 * 上行，RPC请求的处理器
 */
public interface ToServerRpcHandler {

    ListenableFuture<AuthResponseMsg> onBasicAuth(AuthBasicRequestMsg msg);

    ListenableFuture<AuthResponseMsg> onX509Auth(AuthX509RequestMsg msg);

}
